package com.vtron.mq.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.support.Acknowledgment;

/**
 * @date : 2022/4/26 17:59
 * @author: 忻龙彪
 */
public interface IMqListenerService {
    /**
     * 接收到新消息
     * @param record
     * @param ack
     */
    void received(ConsumerRecord<String, String> record, Acknowledgment ack);
}
